package com.xxr.mom.ci.charging.simulation.service;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

/**
 * @description: StationService
 * @date: 2024/8/21 21:36
 * @author: natsuki_kining
 * @version: 1.0
 */
@Service
public class StationService {


    @RocketMQMessageListener(topic = "test-topic", consumerGroup = "my-consumer-group")
    public class MyConsumerListener implements RocketMQListener<String> {
        @Override
        public void onMessage(String message) {
            System.out.println("Received message: " + message);
            // 处理接收到的消息
        }
    }

}
